package com.kingsoft.dc.khaos.module.spark.constants

/**
  * Created by wuxiang on 2021/1/5.
  */
object InfluxConstants {
  // ============================SINK============================
  final val MODULE_INFLUXDB_SINK_WRITE_TIMEOUT = "module.influxdb.sink.write.timeout"
  final val MODULE_INFLUXDB_SINK_READ_TIMEOUT = "module.influxdb.sink.read.timeout"
  final val MODULE_INFLUXDB_SINK_CONNECT_TIMEOUT = "module.influxdb.sink.connect.timeout"
  final val MODULE_INFLUXDB_SINK_REPARTITION_PER_NUMS = "module.influxdb.sink.repartition.per.nums"
  final val MODULE_INFLUXDB_SINK_MAX_PARTITION_NUMS = "module.influxdb.sink.max.partition.nums"

  // ============================SOURCE============================
  final val MODULE_INFLUXDB_SOURCE_WRITE_TIMEOUT = "module.influxdb.sink.write.timeout"
  final val MODULE_INFLUXDB_SOURCE_READ_TIMEOUT = "module.influxdb.sink.read.timeout"
  final val MODULE_INFLUXDB_SOURCE_CONNECT_TIMEOUT = "module.influxdb.sink.connect.timeout"
  final val MODULE_INFLUXDB_SOURCE_DATA_NUMS = "module.influxdb.source.data.nums"

}
